//package com.bsj.power.pls.webSocket;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.stereotype.Component;
//import org.yeauty.annotation.OnClose;
//import org.yeauty.annotation.OnMessage;
//import org.yeauty.annotation.OnOpen;
//import org.yeauty.annotation.ServerEndpoint;
//import org.yeauty.pojo.Session;
//
//import java.util.LinkedList;
//import java.util.List;
//
///**
// * @author LiJiaXin
// * @version 1.0.0
// * @description MyWebSocketEndpoint
// * @time 2024/5/15 10:21
// */
//@Slf4j
//@Component
//@ServerEndpoint(value = "/websocket/alarmPush", port = "8848")
//public class AlarmWebSocket {
//
//    static List<Session> sessions = new LinkedList<>();
//
//    /**
//     * 连接建立
//     *
//     * @param session
//     * @return void
//     * @author ljx
//     * @time 2024/5/15 10:46
//     */
//    @OnOpen
//    public void onOpen(Session session) {
//        log.info("连接建立{}", session);
//        sessions.add(session);
//    }
//
//    /**
//     * 收到客户端消息
//     *
//     * @param message
//     * @return void
//     * @author ljx
//     * @time 2024/5/15 10:47
//     */
//    @OnMessage
//    public void onMessage(String message) {
//        log.info("收到客户端消息{}", message);
//        // TODO 推送位置模拟数据使用
//        send(message);
//    }
//
//    /**
//     * 连接关闭
//     *
//     * @param session
//     * @return void
//     * @author ljx
//     * @time 2024/5/15 10:48
//     */
//    @OnClose
//    public void onClose(Session session) {
//        log.info("连接断开{}", session);
//        sessions.remove(session);
//    }
//
//    /**
//     * 推送报警信息
//     *
//     * @param message
//     * @return void
//     * @author ljx
//     * @time 2024/5/15 10:59
//     */
//    public void send(String message) {
//        for (Session session : sessions) {
//            try {
//                //服务器向客户端发送消息
//                session.sendText(message);
//            } catch (Exception e) {
//                e.printStackTrace();
//            }
//        }
//    }
//}
